package initialize

import (
	"go.uber.org/zap"
	"yunwei/go_api/application/model"
	. "yunwei/go_api/application/services"
)

func InitJob() {
	// 初始化cron
	mainCron := New()
	// 开启调度协程
	mainCron.Start()
	// 查询所有状态为1的任务
	list, _ := model.TaskGetList(1, 10, "status", 1)
	for _, task := range list {
		// 创建job
		job, err := NewJobFromTask(task)
		if err != nil {
			zap.S().Error("初始化job失败")
			continue
		}
		// 添加任务到管道
		_ = MainCron.AddJob(task.CronSpec, *job)
	}
}
